package com.offcn.listener;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @Author: wy
 * @Date: 2022/9/23 17:41
 */
@Component
public class listener02 {

    @RabbitListener(queues = "work_queue")
    public void receive1(String message){
        System.out.println("消费者1："+message);
        /**
         *   2.4 能者多劳
         *
         * 刚才的实现有问题吗？
         *
         * - 消费者1比消费者2的效率要低，一次任务的耗时较长
         * - 然而两人最终消费的消息数量是一样的
         * - 消费者2大量时间处于空闲状态，消费者1一直忙碌
         *
         * 现在的状态属于是把任务平均分配，正确的做法应该是消费越快的人，消费的越多。
         */
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }

    @RabbitListener(queues = "work_queue")
    public void receive2(String message){
        System.out.println("消费者2："+message);
    }
}
